package org.jetlinks.community.messaging.kafka.command;

import lombok.AllArgsConstructor;
import lombok.Getter;
import lombok.Setter;
import org.jetlinks.community.datasource.Command;
import org.jetlinks.community.messaging.kafka.KafkaConsumer;
import org.springframework.boot.autoconfigure.kafka.KafkaProperties;
import reactor.core.publisher.Mono;

import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import java.util.List;

@Getter
@Setter
@AllArgsConstructor
public class CreateConsumer implements Command<Mono<KafkaConsumer>> {

    @Nonnull
    private List<String> topics;

    @Nullable
    private KafkaProperties properties;

}
